from celery import Celery

app = Celery("tasks", broker='redis://localhost:6379/0', backend='redis://localhost')


@app.task
def add(x, y):
    return x + y

from fastapi import BackgroundTasks, FastAPI


app = FastAPI()


def write_notification(email: str, message=""):
    with open("log.txt", mode="w") as email_file:
        content = f"notification for {email}: {message}"
        email_file.write(content)


@app.post("/send-notification/{email}")

async def send_notification(email: str, background_tasks: BackgroundTasks):

    background_tasks.add_task(write_notification, email, message="some notification")
    return {"message": "Notification sent in the background"}
